625cb5e57085ff8168d6719e5e56bc7d977d19b8,MobileBuy/buy/src/main/java/com/shopify/buy/dataprovider/ProductServiceDefault.java,ProductServiceDefault,getCollections,#List#,216

Before Change


        }

        final String queryString = TextUtils.join(",", collectionIds.toArray());
        return retrofitService
            .getCollections(appId, queryString)
            .retryWhen(networkRetryPolicyProvider.provide())
            .doOnNext(new RetrofitSuccessHttpStatusCodeHandler<>())
            .compose(new UnwrapRetrofitBodyTransformer<CollectionListings, List<Collection>>())
            .onErrorResumeNext(new BuyClientExceptionHandler<List<Collection>>())
            .observeOn(callbackScheduler);
    }

    @Override

After Change


        }

        final String queryString = TextUtils.join(",", collectionIds.toArray());
        final Observable<List<Collection>> apiRequest = retrofitService
            .getCollections(appId, queryString)
            .retryWhen(networkRetryPolicyProvider.provide())
            .doOnNext(new RetrofitSuccessHttpStatusCodeHandler<>())
            .compose(new UnwrapRetrofitBodyTransformer<CollectionListings, List<Collection>>())
            .onErrorResumeNext(new BuyClientExceptionHandler<List<Collection>>());

        return ApiInterceptWrapper.wrap(
            apiRequest,
            requestInterceptor,
            responseInterceptor,
            new ApiInterceptWrapper.InterceptorCall<ProductApiInterceptor, List<Collection>>() {
                @Override
                public Observable<List<Collection>> call(ProductApiInterceptor interceptor, Observable<List<Collection>> originalObservable) {
                    return interceptor.getCollections(collectionIds, originalObservable);
                }
            }
        ).observeOn(callbackScheduler);
    }

    @Override